//package cn.iocoder.yudao.module.pi.mq.mq.consumer;
//
//import cn.iocoder.yudao.framework.common.exception.ServiceException;
//import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
//import cn.iocoder.yudao.module.demo.mq.message.DemoInfoSendMessage;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
//import org.apache.rocketmq.spring.core.RocketMQListener;
//import org.springframework.stereotype.Component;
//
///**
// * 针对 {@link DemoInfoSendMessage} 的消费者
// *
// * @author 徐煜东
// */
//@RocketMQMessageListener( // 重点：添加 @RocketMQMessageListener 注解，声明消费的 topic
//        topic = DemoInfoSendMessage.TOPIC,
//        consumerGroup = DemoInfoSendMessage.TOPIC + "_CONSUMER"
//)
//@Component
//@Slf4j
//public class DemoInfoSendConsumer implements RocketMQListener<DemoInfoSendMessage> {
//
//    @Override
//    public void onMessage(DemoInfoSendMessage message) {
//        log.info("[onMessage][消息内容({})]", message);
//        //其他业务逻辑处理
//
//    }
//}
